import celery

#消息中间件(redis)
broker='redis://localhost:6379/1'  #1代表使用第一个库

#结果存储(redis)
backend='redis://localhost:6379/3' #2代表使用第一个库
#实例化得到对象，指定中间件和结果存储
app=celery.Celery('test',broker=broker,backend=backend,include=['celery_task1.order_task','celery_task1.user_task']) #包括分任务的路径，有几个模块的任务，写几个




# 在celery.py中配置
# 时区
app.conf.timezone = 'Asia/Shanghai'
# 是否使用UTC
app.conf.enable_utc = False
# 任务的定时配置
from datetime import timedelta
from celery.schedules import crontab

app.conf.beat_schedule = {
    'send-msg':{
        'task': 'celery_task1.user_task.send_sms',
        # 'schedule': timedelta(hours=24*10),
        # 'schedule': crontab(hour=8, day_of_week=1),  # 每周一早八点
        # 'schedule': crontab(hour=8, day_of_month=1),  # 每月一号早八点
        'schedule': crontab(minute='1'),  # 每分钟
        'args': ('18964352112',),
    }
}




















